from multiprocessing.managers import BaseManager


class QueueManager(BaseManager): pass


# ip = '127.0.0.1'
# ip = 'foo.bar.org'
ip = '127.0.0.1'

QueueManager.register('get_queue')
m = QueueManager(address=(ip, 50000), authkey=b'abracadabra')
m.connect()
queue = m.get_queue()
queue.put('hello')
